package com.eventx.service.rocketmq;

import com.eventx.bus.channel.ChannelConfig;
import org.springframework.boot.context.properties.ConfigurationProperties;

import java.util.Properties;

/**
 * @author: anrror
 **/
@ConfigurationProperties(prefix = "spring.eventx.rocketmq")
public class RocketMqChannelConfig extends ChannelConfig {

    private String hosts;


    public RocketMqChannelConfig(Properties properties) {
        super(properties);
        this.hosts = properties.getProperty("host");
    }


    public String getHost() {
        return hosts;
    }

}
